/*
 * @Author: 段本显
 * @Desc: 文件简介
 * @Date: 2021-08-06 15:22:01
 * @LastEditors: 段本显
 * @LastEditTime: 2021-09-15 14:07:41
 * @Email: duanbenxian@jianq.com
 * @Mark: 如果有bug，那肯定不是我的锅，噜噜噜
 */
/*
 * @Author: 段本显
 * @Desc: 文件简介
 * @Date: 2021-08-03 14:27:41
 * @LastEditors: 段本显
 * @LastEditTime: 2021-08-05 14:07:04
 * @Email: duanbenxian@jianq.com
 * @Mark: 如果有bug，那肯定不是我的锅，噜噜噜
 */
// http.ts
import axios, { AxiosRequestConfig, AxiosResponse, AxiosInstance } from 'axios'
import qs from 'qs'
import showStatus from '@axios/status'

interface AxiosConfig extends AxiosRequestConfig {
  noSQ?: boolean
}

// 配置新建一个 axios 实例
const service: AxiosInstance = axios.create({
  baseURL: '/api',
  timeout: 50000,
  headers: { 'Content-Type': 'application/json' }
})

// Toast.allowMultiple()

const AsyncFun = (promise: Promise<AxiosResponse>): Promise<any> => {
  return promise
    .then((data: AxiosResponse) => {
      return [null, data]
    })
    .catch((err) => {
      err = err || ' '
      console.error(err)
      return [err, {}]
    })
}

let toast: any = null

// 声明一个 Map 用于存储每个请求的标识 和 取消函数
const pending = new Map()
/**
 * 添加请求
 * @param {Object} config
 */
const addPending = (config: AxiosRequestConfig) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&')
  config.cancelToken =
    config.cancelToken ||
    new axios.CancelToken((cancel) => {
      if (!pending.has(url)) {
        // 如果 pending 中不存在当前请求，则添加进去
        pending.set(url, cancel)
      }
    })
}
/**
 * 移除请求
 * @param {Object} config
 */
const removePending = (config: AxiosRequestConfig) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&')
  if (pending.has(url)) {
    // 如果在 pending 中存在当前请求标识，需要取消当前请求，并且移除
    const cancel = pending.get(url)
    cancel(url)
    pending.delete(url)
  }
}

/**
 * 清空 pending 中的请求（在路由跳转时调用）
 */
export const clearPending = () => {
  for (const [url, cancel] of pending) {
    cancel(url)
  }
  pending.clear()
}

// 请求拦截器
service.interceptors.request.use(
  (config: AxiosConfig) => {
    removePending(config) // 在请求开始前，对之前的请求做检查取消操作
    addPending(config) // 将当前请求添加到 pending 中

    //获取token，并将其添加至请求头中
    let token = localStorage.getItem('token')
    if (token) {
      config.headers.Authorization = `${token}`
    }
    if (config.method === 'post' && config.noSQ) {
      config.data = qs.stringify(config.data)
    }
    // toast = Toast.loading({
    //   message: '加载中...',
    //   forbidClick: true,
    //   loadingType: 'spinner',
    //   duration: 0
    // })
    return config
  },
  (error) => {
    // 错误抛到业务代码
    error.data = {}
    error.data.msg = '服务器异常，请联系管理员！'
    // Notify({ type: 'danger', message: error.data.msg, duration: 1300 })
    // return Promise.resolve(error)
    return AsyncFun(Promise.reject(error))
  }
)

// 响应拦截器
service.interceptors.response.use(
  (response: AxiosResponse) => {
    removePending(response) // 在请求结束后，移除本次请求
    const status = response.status
    let msg = ''
    if (status < 200 || status >= 300) {
      // 处理http错误，抛到业务代码
      msg = showStatus(status)
      if (typeof response.data === 'string') {
        response.data = { msg }
      } else {
        response.data.msg = msg
      }
    }
    toast && toast.clear()
    if (response.data.code != '1000') {
      // Notify({ type: 'danger', message: response.data.msg, duration: 1300 })
      return AsyncFun(Promise.reject(response.data))
    }
    response.data.devices = response.data.devices || []
    return AsyncFun(Promise.resolve(response.data))
  },
  (error) => {
    toast && toast.clear()
    if (axios.isCancel(error)) {
      console.log('repeated request: ' + error.message)
    } else {
      // handle error code
      // 错误抛到业务代码
      error.data = {}
      error.data.msg = '请求超时或服务器异常，请检查网络或联系管理员！'
      // Notify({ type: 'danger', message: error.data.msg, duration: 1300 })
      // ElMessage.error(error.data.msg)
    }
    // return Promise.reject(error)
    return AsyncFun(Promise.reject(error))
  }
)

export default service
